package com.example;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 用于模拟用户注册和下单的CDC消息发送
 */
public class CanalCdcUserOrderInsert extends CanalCdcBase {

    private static final Logger logger = LoggerFactory.getLogger(CanalCdcUserOrderInsert.class);

    @Override
    protected String getJsonFilePath() {
        // 指定要读取的JSON文件路径
        return "data_simulator/canal_cdc_t_user_order_insert.json";
    }

    public static void main(String[] args) {
        // 创建实例并处理Canal消息
        CanalCdcUserOrderInsert canalCdc = new CanalCdcUserOrderInsert();
        canalCdc.processCanalMessages();
    }
} 